package com.study.demo.disruptor.entity;

import com.lmax.disruptor.WorkHandler;

public class ConsumerWorkHandler implements WorkHandler<LongEvent> {

    private int no;

    public ConsumerWorkHandler(){

    }
    public ConsumerWorkHandler(int no){
        this.no  = no;
    }

    public void onEvent(LongEvent event) throws Exception {
        System.out.println(no + " 消费数据：" + event.get());
    }
}
